package com.lry.filter;

public class DelayMessageFilter implements MessageFilter{

    @Override
    public boolean filter(Object... obj) {

        long shouldConsumeMills = (long) obj[0];
        if(0!=shouldConsumeMills){
            if(shouldConsumeMills>System.currentTimeMillis()){
                //说明本消息还不可以消费
                return true;
            }
        }
        return false;
    }

}
